java Twitter4j为getCreatedAt和getCountry获取空白或null
我正在使用Twitter4J传输一些Twitter数据,并且我能够生成推文文本。 tweet由正在将文本保存到Kafka的TwitterConsumer类使用。 到目前为止,一切正常。 我的问题是,我试图获得推特的日期和时间以及位置(国家代码足够了)。我知道位置可能为空,但在我的情况下,日期/时间和位置始终为空或空。我一定是做错了什么
样本输出
[Twitter4J Async Dispatcher[0]] INFO uom_bigdataAss1.producer.TwitterProducer - Created on: [Thread-3] INFO uom_bigdataAss1.consumer.TwitterConsumer - Location: No Location [Thread-3] INFO uom_bigdataAss1.consumer.TwitterConsumer - delta plus
- a variant of concern. more transmissible, could even escape vaccines. we will continue to learn more about… [Thread-3] INFO uom_bigdataAss1.consumer.TwitterConsumer - Created at: [Thread-3] INFO uom_bigdataAss1.consumer.TwitterConsumer - User: [Thread-3] INFO uom_bigdataAss1.consumer.TwitterConsumer - User Name: [Thread-3] INFO uom_bigdataAss1.consumer.TwitterConsumer - _________________
这是我用来制作推特流媒体的代码
public class TwitterProducer {
final Logger logger = LoggerFactory.getLogger(TwitterProducer.class);
Thread twitterConsumerThread = null;
//Queue for tweets
private LinkedBlockingQueue<Status> queue;
//stream of tweets
private TwitterStream twitterStream;
private BlockingQueue<String> msgQueue = new LinkedBlockingQueue<>(100);
public static void main(String[] args) {
new TwitterProducer().run();
}
// Twitter Client
public void setTwitterStream(BlockingQueue<String> msgQueue){
/** Setting up a connection */
ConfigurationBuilder cb = new ConfigurationBuilder();
cb.setDebugEnabled(true)
.setOAuthConsumerKey(TwitterConfig.CONSUMER_KEYS)
.setOAuthConsumerSecret(TwitterConfig.CONSUMER_SECRETS)
.setOAuthAccessToken(TwitterConfig.TOKEN)
.setOAuthAccessTokenSecret(TwitterConfig.SECRET);
this.twitterStream = new TwitterStreamFactory(cb.build()).getInstance();
}
private void run(){
logger.info("Setting up");
// 1. Twitter Stream
setTwitterStream(msgQueue);
this.queue = new LinkedBlockingQueue<Status>();
StatusListener listener = new StatusListener() {
@Override
public void onStatus(Status status) {
try {
queue.offer(status, 5000, TimeUnit.MILLISECONDS);
logger.info("Created on:", status.getCreatedAt().getTime());
Place place = status.getPlace();
if (place != null ) {
logger.info("Created on:", place.getCountry());
}
} catch (InterruptedException e) {
// TODO Auto-generated catch block
logger.error("BlockinQueue Full", e);
}
}
@Override
public void onDeletionNotice(StatusDeletionNotice sdn) {
}
@Override
public void onTrackLimitationNotice(int i) {
}
@Override
public void onScrubGeo(long l, long l1) {
}
@Override
public void onException(Exception e) {
e.printStackTrace();
}
@Override
public void onStallWarning(StallWarning warning) {
}
};
twitterStream.addListener(listener);
FilterQuery query = new FilterQuery();
String keywords[] = {"covid", "vaccine"};
query.track(keywords);
query.language("en");
twitterStream.filter(query);
// Shutdown Hook
Runtime.getRuntime().addShutdownHook(new Thread( () -> {
logger.info("Application is now stopping!");
twitterStream.shutdown();
//logger.info("Closing Producer");
//producer.close();
logger.info("Closing twitterConsumer");
this.twitterConsumerThread.interrupt();
logger.info("Finished closing");
logger.info("\n Application End");
}));
logger.info("Running Twitter Consumer");
TwitterConsumer twitterConsumer = new TwitterConsumer(this.queue);
this.twitterConsumerThread = new Thread(twitterConsumer);
twitterConsumerThread.start();
}
}
你知道会发生什么事/原因吗
# 1 楼答案
更改日志语句,如
及
您缺少{}-占位符
通过上述更改,日志将类似于
检查http://www.slf4j.org/manual.html#typical_usage
此外,并非所有的状态都带有国家信息